package com.wfg.flink.connector.constants;

/**
 * @author wfg
 */
public class Constants {
    public static final String KAFKA_BROKERS = "192.168.1.12:9092";
    public static final String TOPIC_NAME = "TOPIC_WellCastingInfo";
    public static final String TEST_TOPIC_PV = "TEST_TOPIC_PV";
    // Mongo
    public static final String MONGO_TEST_PV_COLLECTION = "TestMongoPv";
}